const mysql = require('mysql2')
const MY_SQL_CONFIG = require('../../conf/db')

// 创建数据库连接
const connect = mysql.createConnection(MY_SQL_CONFIG)

// 监听mysql链接
connect.connect((err) => {
  if (err) {
    console.log('数据库连接失败')
    console.log(err)
  } else {
    console.log('数据库连接成功')
  }
})

// 封装查询方法
const sqlQuery = (sql) => {
  return new Promise((resolve, reject) => {
    connect.query(sql, (err, results) => {
      if (err) {
        reject(err)
        return
      } else {
        console.log(results, '----- 数据库查询返回的数据 -----')
        resolve(results)
      }
    })
  })
}
module.exports = {
  sqlQuery,
}
